package com.fyyg.monitor.job;

import java.util.Queue;
import java.util.concurrent.ConcurrentLinkedQueue;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

/**
 * 核对用户资金任务
 *
 * @author hang.ouyang
 * @date 2016-06-08 14:22
 */
public class CheckUserMoneyTask {
    private final static Logger logger = LogManager.getLogger(CheckUserMoneyTask.class);

    public CheckUserMoneyTask(){
        logger.info("CheckUserMoneyTask init");
    }

    private volatile String batchTime;
    Queue<Integer> batchUserQueue = new ConcurrentLinkedQueue<>();

    public void execute(){

        //待监控用户队列为空则进行下批次任务否则继续处理上批次任务
        if(batchUserQueue.isEmpty()) {
            batchTime = System.currentTimeMillis() / 1000L + "";
        }else {
            return;
        }
        //查询上一批次任务时间



    }

}
